﻿using Microsoft.Extensions.Logging;
using System.Threading.Tasks;

namespace Fast.Extensions.EventBus.RabbitMQ.Subscribe.Tests
{
    /// <summary>
    /// 处理死信队列
    /// </summary>
    public class TestEventExceptionHandler : IIntegrationEventExceptionHandler<TestEventException>
    {
        private readonly ILogger<TestEventHandler> _logger;
        public TestEventExceptionHandler(ILogger<TestEventHandler> logger)
        {
            _logger = logger;
        }
        public Task HandleAsync(TestEventException @event)
        {
            _logger.LogInformation("处理死信队列");

            return Task.CompletedTask;
        }
    }
}
